package com.lee.rpc.comsumer.test;

import java.nio.channels.SelectionKey;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.atomic.AtomicInteger;

import com.lee.rpc.protocal.core.RequestHolder;
import com.lee.rpc.protocal.core.RpcFuture;
import com.lee.rpc.protocal.core.RpcResponse;

import io.netty.channel.DefaultEventLoop;
import io.netty.util.concurrent.DefaultPromise;

public class Temp {
	
 
	public static void main(String[] args) throws InterruptedException, ExecutionException { 
		 
		//System.out.println( & (threadsLength )); 
		//00001000
		//00000011 
		System.out.println(SelectionKey.OP_ACCEPT);
		System.out.println(SelectionKey.OP_CONNECT);
		System.out.println(SelectionKey.OP_READ);
		System.out.println(SelectionKey.OP_WRITE);
	}
	 
	private static final class T {
		private final AtomicInteger idx = new AtomicInteger();
		
	}
	
	 
	 
 

}
